package org.cainiao.basic.reactive.source;

import java.util.List;

public interface MyMessageProcessor<T> {

    void register(MyMessageListener<T> myEventListener);

    List<T> getHistory(long i);

}
